ccd8cb240726deda35fabd2860edcbf4adeb1013,hoodie-hadoop-mr/src/main/java/com/uber/hoodie/hadoop/HoodieInputFormat.java,HoodieInputFormat,listStatus,#JobConf#,79

Before Change


                Integer maxCommits = HoodieHiveUtil.readMaxCommits(Job.getInstance(job), tableName);
                LOG.info("Last Incremental timestamp was set as " + lastIncrementalTs);
                List<String> commitsToReturn =
                    timeline.findInstantsAfter(lastIncrementalTs, maxCommits)
                        .collect(Collectors.toList());
                List<HoodieDataFile> filteredFiles =
                    fsView.streamLatestVersionInRange(value, commitsToReturn)
                        .collect(Collectors.toList());

After Change


                Integer maxCommits = HoodieHiveUtil.readMaxCommits(Job.getInstance(job), tableName);
                LOG.info("Last Incremental timestamp was set as " + lastIncrementalTs);
                List<String> commitsToReturn =
                    timeline.findInstantsAfter(lastIncrementalTs, maxCommits).getInstants()
                        .map(HoodieInstant::getTimestamp).collect(Collectors.toList());
                List<HoodieDataFile> filteredFiles =
                    fsView.getLatestVersionInRange(value, commitsToReturn)
                        .collect(Collectors.toList());